//package com.mango.iot.gateway.tcp.mq;
//
//import cn.hutool.core.lang.UUID;
//import cn.hutool.core.util.IdUtil;
//import com.alibaba.fastjson.JSON;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * RabbitMQ 生产者
// *
// * @author  liangfeihu
// * @since  2023/6/27 16:36
// */
//@Slf4j
//@Component
//public class RabbitMqProducer {
//
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    public void send(String topic, Object msg) {
//        try {
//            rabbitTemplate.convertAndSend(topic, msg);
//            log.info("mqs message topic:{},msg:{}", topic, JSON.toJSONString(msg));
//        } catch (Exception e) {
//            log.error("mqs send msg error", e);
//        }
//    }
//
//}
